import $http from '@/api/index.js'
var  session
class socketIO {
	constructor(e) {
		this.socketTask = null
		this.is_open_socket = false //避免重复连接
		this.is_show_Loading  = true
		this.url = 'ws://120.46.147.246:9206/ws/path/asset/'+e //连接地址
		// this.url = 'ws://192.168.31.27:9206/ws/pushMessage/'+e
		this.connectNum = 1 // 重连次数
		this.followFlake = true // traderDetailIndex == true 重连
		//心跳检测
		this.timeout = 15000 //多少秒执行检测
		this.heartbeatInterval = null //
		this.reconnectTimeOut = null //
	}
 
	// 进入这个页面的时候创建websocket连接【整个页面随时使用】
	connectSocketInit() {
		this.socketTask = uni.connectSocket({
			url: this.url,
			success: () => {
				console.log("正准备建立websocket中...");
				// 返回实例
				return this.socketTask
			},
		});
		
		this.socketTask.onOpen((res) => {
			this.connectNum = 1
			console.log("WebSocket连接正常！");
			 
			clearInterval(this.reconnectTimeOut)
			clearInterval(this.heartbeatInterval)
			this.is_open_socket = true;
			this.is_show_Loading = true;
			uni.hideLoading()
			this.start();
			// 注：只有连接正常打开中 ，才能正常收到消息
			this.socketTask.onMessage((e) => {
				console.log(uni.getStorageSync("userid"),11111)
				// 字符串转json
				let res = '变化了';
				let fromdata = {}
				let data =JSON.parse(JSON.stringify(e))
				fromdata=data.data
				const keyValuePairs = fromdata.replace('{', '').replace('}', '').split(',');
				const mood = {};
				keyValuePairs.forEach(keyValue => {
					const [key, value] = keyValue.split(/[=]/);
					mood[key.trim()] = value.trim();
				});
				session = mood.session
				// console.log("res---------->", res) // 这里 查看 推送过来的消息
				uni.$emit('getPositonsOrder',e);
			});
		})
 
 
 
		// 监听连接失败，这里代码我注释掉的原因是因为如果服务器关闭后，和下面的onclose方法一起发起重连操作，这样会导致重复连接
		uni.onSocketError((res) => {
			// console.log('WebSocket连接打开失败，请检查！', this.connectNum);
			
			// if(this.is_show_Loading){
			// 	uni.showLoading({
			// 		title: `正在尝试重连`,
			// 		mask: true
			// 	})
			// }
			
			
			// this.socketTask = null
			// this.is_open_socket = false;
			// this.is_show_Loading = false;
			// clearInterval(this.heartbeatInterval)
			// clearInterval(this.reconnectTimeOut)
			// uni.$off('getPositonsOrder')
			// if (this.connectNum < 6000) {
			
			// this.reconnect();
			// this.connectNum += 1
			// } else {
			// uni.$emit('connectError');
			// this.connectNum = 1
			// }
 
		});
 
		// 这里仅是事件监听【如果socket关闭了会执行】
	// 	this.socketTask.onClose(() => {
	// 		console.log("已经被关闭了-------")
	// 		clearInterval(this.heartbeatInterval)
	// 		clearInterval(this.reconnectTimeOut)
	// 		this.is_open_socket = false;
	// 		this.is_show_Loading = false;
	// 		this.socketTask = null
	// 		// uni.$off('getPositonsOrder')
	// 		if (this.connectNum < 6) {
	// 			this.reconnect();
	// 		} else {
	// 			uni.$emit('connectError');
	// 			this.connectNum = 1
	// 		}
 
	// 	})
	}
 
 
 
 
	// 主动关闭socket连接
	Close() {
		if (!this.is_open_socket) {
			return
		}
		
		var that = this;
		this.socketTask.close({
			success() {
				console.log('关闭成功')
				uni.setStorageSync('session',session)
			}
		});
	}
	//发送消息
	send(data) {
		// console.log("data---------->", data);
		// 注：只有连接正常打开中 ，才能正常成功发送消息
		if (this.socketTask) {
			this.socketTask.send({
				data: JSON.stringify(data),
				async success() {
					// console.log("消息发送成功");
				},
			});
		}
	}
 
 
	//开启心跳检测
	start() {
		this.heartbeatInterval = setInterval(() => {
			this.send({
				action: '1003',
				version: '1',
				data: {
					msg: ''
				}
			});
		}, this.timeout)
	}
 
 
	//重新连接
	reconnect() {
		//停止发送心跳
		clearInterval(this.heartbeatInterval)
		//如果不是人为关闭的话，进行重连
		if (!this.is_open_socket && this.followFlake) {
			this.reconnectTimeOut = setInterval(() => {
				this.connectSocketInit(this.data);
			}, 3000)
		}
	}
 
}
module.exports = socketIO